package com.hxk.merge

import com.hxk.spark.merge.LogMessage

object RawDataParser {

  /**
    * 对原始数据进行处理
    * @param line 输入原始数据的每一行
    * @return 解析之后的LogMessage类
    */
  def parse(line: String): LogMessage = {
    //1.使用逗号对方法输入进来的一行数据进行切割
    val fields = line.split(",")
    //2.创建LogMessage对象
    val logMessage = new LogMessage()
    //3.对logMessage里面的每个字段进行设置
    logMessage.setUserId(fields(0))
    logMessage.setLocation(fields(1))
    logMessage.setStartTime(fields(2))
    logMessage.setResidenceTime(fields(3).toInt)
    //4.函数返回
    logMessage
  }
}
